package com.cailu.receiver.config;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.cailu.common.constant.SenderConfTopicCommon;

/**
 * @author cailu
 * @filename SenderConfTopicReceiver
 * @description Topic转发模式
 * @date 2020/3/31 15:37
 */
@Component
public class SenderConfTopicReceiver {

	@RabbitListener(queues = SenderConfTopicCommon.DIRECT_TOPIC_MESSAGE)
	public void processTopicQueue(String str) {
		System.out.println("Receive---topic_message:========================:" + str.toString());
	}

	@RabbitListener(queues = SenderConfTopicCommon.DIRECT_TOPIC_TO_MESSAGE)
	public void processTopicToeMSQueue(String str) {
		System.out.println("Receive---由topic_message转发到topic_to_message:========================:" + str.toString());
	}
}
